package dashboard.jedis;

import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.junit.Before;
import org.junit.Test;

import redis.clients.jedis.Jedis;

public class TestRedis {
    private Jedis jedis; 
    
    @Before
    public void setup() {
        //连接redis服务器，10.9.19.123:6379
        jedis = new Jedis("10.9.19.123", 6379);
//        权限认证
//        jedis.auth("admin");  
//		jedis.flushDB();// 删除当前数据库中所有key,此方法不会失败。慎用
//		jedis.flushAll();// 删除所有数据库中的所有key，此方法不会失败。更加慎用
    }
    
    /**
     * redis存储字符串
     * 给定模式 pattern 的 key； * 匹配数据库中所有 key；KEYS h?llo 匹配 hello，hallo等。KEYS h[ae]llo匹配hello和hallo
     */
    @Test
    public void testString() {
    	 System.err.println("redis存储字符串:");
        //-----添加数据----------  
        jedis.set("name","xinxin");//向key-->name中放入了value-->xinxin  
        System.out.println(jedis.get("name"));//执行结果：xinxin  
        
        jedis.append("name", " is my lover"); //拼接
        System.out.println(jedis.get("name")); 
//        jedis.zrange(key, start, end);
        jedis.del("name");  //删除某个键
        System.out.println(jedis.get("name"));
        //设置多个键值对
        jedis.mset("name","liuling","age","23","qq","476777389");
       
        jedis.incr("age"); //进行加1操作
        System.out.println(jedis.get("name") + "-" + jedis.get("age") + "-" + jedis.get("qq"));
        System.out.println();
    }
    
    /**
     * redis操作Map
     */
    @Test
    public void testMap() {
    	System.err.println("redis操作Map:");
        //-----添加数据----------  
        Map<String, String> map = new HashMap<String, String>();
        map.put("name", "xinxin");
        map.put("age", "22");
        map.put("qq", "123456");
        jedis.hmset("user",map);
        //取出user中的name，执行结果:[minxr]-->注意结果是一个泛型的List  
        //第一个参数是存入redis中map对象的key，后面跟的是放入map中的对象的key，后面的key可以跟多个，是可变参数  
        List<String> rsmap = jedis.hmget("user", "name", "age", "qq");
        System.out.println(rsmap);  
  
        //删除map中的某个键值  
        jedis.hdel("user","age"); 
//        String jedis.hget(key, field)
//        List<String> jedis.hmget(key, fields,..)
        System.out.println(jedis.hmget("user", "age")); //因为删除了，所以返回的是null  
        System.out.println(jedis.hlen("user")); //返回key为user的键中存放的值的个数2 
        System.out.println(jedis.exists("user"));//是否存在key为user的记录 返回true  
        System.out.println(jedis.hkeys("user"));//返回map对象中的所有key  
        System.out.println(jedis.hvals("user"));//返回map对象中的所有value 
//        Map<String, String> = jedis.hgetAll(key);
        Iterator<String> iter=jedis.hkeys("user").iterator();  
        while (iter.hasNext()){  
            String key = iter.next();  
            System.out.println(key+":"+jedis.hmget("user",key));  
        }  
        System.out.println();
    }
    
    /** 
     * jedis操作List 
     */  
    @Test  
    public void testList(){  
    	System.err.println("redis操作List:");
        //开始前，先移除所有的内容  
        jedis.del("java framework");  
        System.out.println(jedis.lrange("java framework",0,-1));  
        //先向key java framework中存放三条数据  
        jedis.lpush("java framework","spring");  
        jedis.lpush("java framework","struts");  
        jedis.lpush("java framework","hibernate");  
        //再取出所有数据jedis.lrange是按范围取出，  
        /*第一个是key，第二个是起始位置，第三个是结束位置，jedis.llen获取长度 -1表示取得所有
         * 以-1表示列表的最后一个元素，-2表示列表的倒数第二个元素，以此类推  
         * stop下标也在LRANGE命令的取值范围之内(闭区间)
         * 超出范围的下标值不会引起错误
         * */
        System.out.println(jedis.lrange("java framework",0,-1)); 
//        jedis.lpop(key); //非阻塞
//        jedis.blpop(timeout, String .. keys);	//阻塞，相同的key可以被多个客户端同时阻塞。不同的客户端被放进一个队列中，按”先阻塞先服务”(first-BLPOP，first-served)的顺序为key执行BLPOP命令。
        jedis.del("java framework");
        jedis.rpush("java framework","spring");  
        jedis.rpush("java framework","struts");  
        jedis.rpush("java framework","hibernate"); 
        System.out.println(jedis.lrange("java framework",0,-1));
    }  
    
    /** 
     * jedis操作Set 
     */  
    @Test  
    public void testSet(){
    	System.out.println();
    	System.err.println("redis操作Set:");
        //添加    当key为"user" 时无法添加，why?因为之前user设置为map
        jedis.sadd("users","liuling");  
        jedis.sadd("users","xinxin");  
        jedis.sadd("users","ling");  
        jedis.sadd("users","zhangxinxin");
        jedis.sadd("users","who"); 
        //移除noname  
        jedis.srem("users","who");
        System.out.println(jedis.smembers("users"));//获取所有加入的value  
        System.out.println(jedis.sismember("users", "who"));//判断 who 是否是user集合的元素  
        System.out.println(jedis.srandmember("users"));  
        System.out.println(jedis.scard("users"));//返回集合的元素个数  
    }  
    
    /** 
     * jedis 排序  
     */  
    @Test  
    public void testSort(){  
        //jedis 排序  
    	System.out.println();
    	System.err.println("redis排序:");
        //注意，此处的rpush和lpush是List的操作。是一个双向链表（但从表现来看的）  
        jedis.del("a");//先清除数据，再加入数据进行测试  
        jedis.rpush("a", "1");  
        jedis.lpush("a","6");  
        jedis.lpush("a","3");  
        jedis.lpush("a","9");
        System.out.println(jedis.lrange("a",0,-1));// [9, 3, 6, 1]  
        System.out.println(jedis.sort("a")); //[1, 3, 6, 9]  //输入排序后结果  
        System.out.println(jedis.lrange("a",0,-1));  
    }  
    
    
    @Test
    public void testRedisPool() {
    	System.out.println();
    	System.err.println("redis排序:");
    	Jedis jedis =  JedisUtil_V1.getJedis();
    	jedis.set("newname", "中文测试");
        JedisUtil_V1.returnResource(jedis);
//        jedis.set("newname", "测试");
//        System.out.println(jedis.get("newname"));
        
        Jedis jedis2 =  JedisUtil_V1.getJedis();
        System.out.println(jedis.equals(jedis2));
        JedisUtil_V1.returnResource(jedis2);
        System.out.println(jedis2.get("newname"));
       
    }
    
    /*
     * 失效时间： jedis.expire(key seconds) ;  jedis.setex("user.userid.14101", 5, "James");
     * 去掉key的expire设置：不再有失效时间  jedis.persist("user.userid.14101");
    */
    
	/*
	* 自增的整型： int类型采用string类型的方式存储 jedis.set("amount", 100 + "");
	*  递增或递减：incr()/decr() jedis.incr("amount");
	*  增加或减少：incrBy()/decrBy() jedis.incrBy("amount", 20);
	*/
    
	/*
	* 清空当前db： jedis.flushDB();
	* 清空所有db：jedis.flushAll();
	*  增加或减少：incrBy()/decrBy() jedis.incrBy("amount", 20);
	*/  
    /**
     *  5. 事务支持： 
	@ 获取事务：
		Transaction tx = jedis.multi();
	@ 批量操作：tx采用和jedis一致的API接口
		for(int i = 0;i < 10;i ++) {
		     tx.set("key" + i, "value" + i); 
		     System.out.println("--------key" + i);
		     Thread.sleep(1000);  
		}
	@ 执行事务：针对每一个操作，返回其执行的结果，成功即为Ok
		List<Object> results = tx.exec();
     */
    
//    public static void main(String[] args){
//    	TestRedis jTestRedis = new TestRedis();
//    	jTestRedis.setup();
//    	
//    }
}